package internal
//
//import (
//	"game-server/msg"
//	"game-server/base"
//	"game-server/log"
//	"reflect"
//	"time"
//)
//
//func init() {
//	// 向当前模块（game 模块）注册 聊天 消息的消息处理函数 handleChatMessage
//	handler(&msg.MsgChatMessage{}, handleChatMessage)
//	// 处理公告广播
//	handler(&msg.MsgBulletin{}, handleBulletin)
//}
//
//func handler(m interface{}, h interface{}) {
//	skeleton.RegisterChanRPC(reflect.TypeOf(m), h)
//}
//
//// 聊天消息处理
//func handleChatMessage(args []interface{}) {
//	message := args[0].(*msg.MsgChatMessage)
//	//conn := args[1].(gate.Agent)
//
//	message.Time = time.Now().Unix()
//	log.Info("Chat: message == ", message)
//
//	info := base.Get("user", message.GetUserId())
//	if info != nil {
//		userInfo:= info.(base.UserInfo)
//		if userInfo.RoomNo > 0 && base.Get("room", userInfo.RoomNo) != nil {
//			roomInfo := base.Get("room", userInfo.RoomNo).(base.Pk)
//			for _, v := range roomInfo.Players {
//				if base.InitConn[v.PlayerId] != nil {
//					base.InitConn[v.PlayerId].WriteMsg(message)
//				}
//			}
//		}
//	} else {
//		log.Info("Chat: error == ", message)
//	}
//}
//
//// 处理公告广播
//func handleBulletin(args []interface{}) {
//	log.Debug("enter to chat module handleBulletin...")
//	msg := args[0].(*msg.MsgBulletin)
//	log.Debug(msg)
//
//	for conn := range agents {
//		conn.WriteMsg(msg)
//	}
//}